package com.biz.primus.ms.product.stream;

import com.biz.primus.search.stream.ProductSearchIndexChannel;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @author jiangnan
 * @Description:
 */
public interface ProductIndexSource extends ProductSearchIndexChannel{

    /**
     * 全量索引 output
     * @return
     */
    @Output(PRODUCT_INDEX_ALL)
    MessageChannel indexAllOutput();

    /**
     * 增量索引 output
     * @return
     */
    @Output(PRODUCT_INDEX_INCR)
    MessageChannel indexIncrOutput();


}
